package org.apache.rocketmq.store;

import org.apache.rocketmq.common.message.MessageExtBatch;
import org.apache.rocketmq.common.message.MessageExtBrokerInner;

import java.nio.ByteBuffer;


public interface AppendMessageCallback {


    AppendMessageResult doAppend(final long fileFromOffset, final ByteBuffer byteBuffer,
                                 final int maxBlank, final MessageExtBrokerInner msg, PutMessageContext putMessageContext);


    AppendMessageResult doAppend(final long fileFromOffset, final ByteBuffer byteBuffer,
                                 final int maxBlank, final MessageExtBatch messageExtBatch, PutMessageContext putMessageContext);
}